//引入express模块
const express = require('express')
//引入数据库连接模块
const pool = require('../pool.js')
//引入公用函数
const xsp_fn = require('../others/xsp_fn')
//创建路由器对象
const mR = express.Router()
//以下为接口部分

//接口方式：get
// mR.get("/qd", (req, res, next) => {
//     pool.query("select * from qiandao", (err, data) => {
//       if (err) {
//         console.log(err);
//         next(err);
//         return;
//       }
//       res.send({ code: 1, msg: "查询成功", data });
//     });
//   });

//查看签到日期
//接口地址：http://127.0.0.1:3000/qiandao/qd
//接口方式：get
mR.get('/qd', (req, res, next) => {
  // console.log(req.query.uid);
  pool.query(
    'select * from qiandao where user_id=?',
    [req.query.user_id],
    (err, data) => {
      if (err) {
        console.log(err)
        next(err)
        return
      }
      res.send({ code: 1, msg: '查询成功', data })
    }
  )
})

//添加签到日期
//接口地址：http://127.0.0.1:3000/qiandao/add
//接口方式：get
// mR.post("/add", (req, res, next) => {
//   // console.log(req.query.uid);
//   let c_add = xsp_fn.api_add("qiandao");
//   pool.query(c_add.sql, [req.body], (err, data) => {
//     if (err) {
//       res.send(c_add.err);
//       next(err);
//     } else {
//       console.log(data);
//       res.send(c_add.success);
//     }
//   });
// });
//添加签到日期
//接口地址：http://127.0.0.1:3000/qiandao/add
//接口方式：post
mR.post('/add', (req, res, next) => {
  //获取post传递的参数
  let obj = req.body
  console.log(obj)
  let sql = `INSERT INTO qiandao(user_id,sign_time,sign_type,sign_day) VALUES (?,?,?,?)`
  //执行SQL命令，将数据插入到数据库
  pool.query(
    sql,
    [obj.user_id, obj.sign_time, obj.sign_type, obj.sign_day],
    (err, data) => {
      // 增加之前
      // 先识别user_id
      // 在修改 obj.sign_time, obj.sign_type, obj.sign_day
      if (err) {
        res.send({ code: 0, msg: '添加失败！' })
        return next(err)
      } else {
        console.log(data)
        //把成功的结果响应
        res.send({ code: 1, msg: '添加成功', data })
      }
    }
  )
})

//暴露出去
module.exports = mR
